package com.ronan.imserver.processor;

import com.ronan.common.proto.Message;
import io.netty.channel.Channel;
import lombok.extern.slf4j.Slf4j;

/**
 * FileName    : com.ronan.imserver.processor
 * Description : 推送消息的处理器
 *
 * @author : ronan
 * @version : 1.0
 * Create Date : 2021/2/26 11:05
 **/
@Slf4j
public class MessageProcessor implements RIMProcessor<Message> {
    @Override
    public void process(Message msg, Channel channel) {
        log.info("接收到数据:message => {}", msg);
        // 对收到的消息进行推送

    }
}
